package cn.test.rabbitmq.spring;

import cn.test.MqBean;

/**
 * @author hanchao
 * @date 2017/7/3 18:33
 */
public class MessageConsumer2 {
    public void consume(MqBean message) {
        System.out.println("bean message>>> "+message);
        //该异常可以确认消息
        //throw new AmqpRejectAndDontRequeueException("gungunm,");
    }
}
